package com.wave.wavesystem.threadpool;

import io.netty.util.concurrent.DefaultThreadFactory;

import java.util.concurrent.*;

public class WaveThreadPoolFactory {


    /**
     * ai 自动评论线程池
     */
    public static ExecutorService aiAutoCommentPool() {
        return new ThreadPoolExecutor(
                1,
                3,
                2L,
                TimeUnit.MINUTES,
                new ArrayBlockingQueue<>(10),
                new DefaultThreadFactory("ai-auto-comment-pool")
        );
    }

}
